package com.xu.serviceconsumer.services;

import com.xu.serviceconsumer.interfaces.MySource;
import com.xu.serviceconsumer.interfaces.ReceviceMsg;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(value = {MySource.class})
public class ReceviceMsgImpl implements ReceviceMsg {

    private static Logger logger = LoggerFactory.getLogger(ReceviceMsgImpl.class);

    @StreamListener(MySource.INPUT_CHANNEL)
    @Override
    public void receive(String message) {

        logger.info("8090客户端接收消息："+message);
    }
}


